﻿using KafkaUtil.Integration;
using Microsoft.Extensions.DependencyInjection;
using System;

namespace KafkaUtil.Interface
{
    public interface IKafkaConsumerBuilder
    {
        IServiceCollection Services { get; }

        IKafkaConsumerBuilder AddListener(Action<IServiceProvider, RecieveResult> onMessageRecieved);
    }
}
